/*
 * Copyright (c) 2020-2099 the original author or authors. All rights reserve.
 */
package org.tianyun.cloud.amqp.rabbitmq.message;

import org.springframework.amqp.AmqpException;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessagePostProcessor;

/**
 * 接受后消息处理
 *
 * @auther ebert_chan
 */
public class AfterReceivePostProcessor implements MessagePostProcessor {

    /*
     * @see org.springframework.amqp.core.MessagePostProcessor#postProcessMessage(org.springframework.amqp.core.Message)
     */
    @Override
    public Message postProcessMessage(Message message) throws AmqpException {
        // MessageProperties messageProperties = message.getMessageProperties();
        // if (messageProperties == null) {
        // return message;
        // }
        // Map<String, Object> headers = messageProperties.getHeaders();
        // ServletContext.setContextMap(headers);
        return message;
    }

}
